package com.bd08.flink.demo.zhang.table

import org.apache.flink.api.scala.{ExecutionEnvironment, createTypeInformation}
import org.apache.flink.table.api.{EnvironmentSettings, TableEnvironment}

object TableDemo2 {
/*
  val benv = EnvironmentSettings.inStreamingMode()
  val tenv = TableEnvironment.create(benv)
  val ds=benv.from(("Jason","9","2010-1-1"),("Tom","9","2010-1-1"))
  tenv.registerDataSet("users",ds,'name,'age,'rowtime)
  val tb=tenv.scan("users")
  tb.printSchema()
  tb.select('*).toDataSet[Row].print()  //'*表示所有字段
*/

}
